bed36fff4ff92353d20582596f0eb7dcb4d79391,src/org/jgroups/protocols/pbcast/FLUSH.java,FLUSH,onStartFlush,#Address#FlushHeader#,654

Before Change


         flushMembers.removeAll(suspected);
      }
      Message msg = new Message(null, localAddress, null);
      msg.putHeader(getName(), new FlushHeader(FlushHeader.FLUSH_OK, fh.viewID));
      down_prot.down(new Event(Event.MSG, msg));
      if (log.isDebugEnabled())
         log.debug("Received START_FLUSH at " + localAddress + " responded with FLUSH_OK");
   }

After Change


         flushMembers.removeAll(suspected);
         amIParticipant = flushMembers.contains(localAddress);
      }
      if (amIParticipant)
      {
         Message msg = new Message(null);
         msg.putHeader(getName(), new FlushHeader(FlushHeader.FLUSH_OK, fh.viewID));
         down_prot.down(new Event(Event.MSG, msg));
         if (log.isDebugEnabled())
            log.debug("Received START_FLUSH at " + localAddress + " responded with FLUSH_OK");
      }